package com.diaohaiwen.framework.mq.rocket.constant;

/**
 * @author 刁海文
 * @since 2024/1/15 23:13
 */
public interface RocketHeaderConst {

    String keys = "keys";

    String topic = "topic";

    String tags = "tags";
    String msgId = "msgId";

    String brokerName = "brokerName";

    String queueId = "queueId";

    String queueOffset = "queueOffset";

    String bornTimestamp = "bornTimestamp";
    String bornHost = "bornHost";

    String storeSize = "storeSize";
    String storeHost = "storeHost";
    String storeTimestamp = "storeTimestamp";
    String commitLogOffset = "commitLogOffset";
    String bodyCRC = "bodyCRC";
    String reconsumeTimes = "reconsumeTimes";

    String preparedTransactionOffset = "preparedTransactionOffset";
    String sysFlag = "sysFlag";


    static String[] systemProperties() {
        return new String[]{keys, topic, tags, msgId, brokerName, queueId, queueOffset, bornHost, bornTimestamp, storeHost, storeSize, storeTimestamp, commitLogOffset, bodyCRC, reconsumeTimes, preparedTransactionOffset, sysFlag};
    }

}
